package com.hung.trade.common.rocketmq;

import org.apache.rocketmq.common.message.MessageExt;

/**
 * @author hungki
 * @createTime 2018-10-08 上午 9:08
 */
public interface IMessageProcesser {
    /**
     * @param messageExt
     * @return
     */
    boolean heandlerMessage(MessageExt messageExt);
}
